/**
 * 数据库模块
*/

let config = require('../Configs');
let Promise = require('bluebird');
let mysql = Promise.promisifyAll(require('mysql'));
var async = require('async');

// class TestCenterPool {
//     constructor() {
//         this.pool = Promise.promisifyAll(mysql.createPool(config.db.testcenterMysql));
//     }

//     async getPool() {
//         return this.pool;
//     }

//     async execQuery(options) {
//         let connection = null;
//         try {
//             connection = await this.pool.getConnectionAsync();
//         } catch (error) {
//             console.log('DB-获取数据库连接异常！');
//             throw error;
//         }
//         // 查询参数
//         let sql = options['sql'];
//         let args = options['args'];
//         // let handler = options['handler'];

//         let results = [];
//         try {
//             // 执行查询
//             if (!args) {
//                 results = await connection.query(sql);
//             } else {
//                 results = await connection.query(sql, args);
//             }
//         } catch (error) {
//             console.log('DB-执行查询语句异常！');
//             throw error;
//         }

//         // await handler(results);

//         // 返回连接池
//         try {
//             await connection.release();
//         } catch (error) {
//             console.log('DB-关闭数据库连接异常！');
//             throw error;
//         }
//         return results;
//     }
// }

// function _getNewSqlParamEntity(sql, params, callback) {
//     console.log(sql, params, callback)
//     if (callback) {
//         return callback(null, {
//             sql: sql,
//             params: params
//         });
//     }
//     return {
//         sql: sql,
//         params: params
//     };
// }

var execTrans = function execTrans(sqlparamsEntities, callback) {
    module.exports.pool.getConnection(function (err, connection) {
        if (err) {
            return callback(err, null);
        }
        connection.beginTransaction(function (err) {
            if (err) {
                return callback(err, null);
            }
            // console.log("开始执行transaction，共执行" + sqlparamsEntities.length + "条数据");
            var funcAry = [];
            sqlparamsEntities.forEach(function (sql_param) {
                var temp = function (cb) {
                    var sql = sql_param.sql;
                    var param = sql_param.params;
                    // sql_param= _getNewSqlParamEntity(sql_param);
                    connection.query(sql, param, function (tErr, rows, fields) {
                        if (tErr) {
                            connection.rollback(function () {
                                // console.log("事务失败，" + sql_param + "，ERROR：" + tErr);
                                throw tErr;
                            });
                        } else {
                            return cb(null, 'ok');
                        }
                    })
                };
                funcAry.push(temp);
            });

            async.series(funcAry, function (err, result) {
                // console.log("transaction error: " + err);
                if (err) {
                    connection.rollback(function (err) {
                        // console.log("transaction error: " + err);
                        connection.release();
                        return callback(err, null);
                    });
                } else {
                    connection.commit(function (err, info) {
                        // console.log("transaction info: " + JSON.stringify(info));
                        if (err) {
                            // console.log("执行事务失败，" + err);
                            connection.rollback(function (err) {
                                // console.log("transaction error: " + err);
                                connection.release();
                                return callback(err, null);
                            });
                        } else {
                            connection.release();
                            return callback(null, info);
                        }
                    })
                }
            })
        });
    });
}

module.exports =  {
    pool: Promise.promisifyAll(mysql.createPool({...config.db.testCenterMysql})),
    execTrans: Promise.promisify(execTrans)
}